home *** CD-ROM | disk | FTP | other *** search
/ Celestin Apprentice 5 / Apprentice-Release5.iso / Source Code / Libraries / DCLAP 6d / dclap6d / DNet.more / DPOP.cp next >
Encoding:
Text File  |  1996-07-05  |  7.5 KB  |  359 lines  |  [TEXT/R*ch]
  1. // UPOP.cp 
  2. // POP Mail reader
  3. //by D. Gilbert, May 1991
  4.  
  5.  
  6.             
  7. /*  ---   general use: ------------
  8.         TPOP        VAR  aPop;
  9.         
  10.         New(aPop); 
  11.         FailNIL(aPop);
  12.         aPop->IPOP( 'cricket.bio.indiana.edu', 'anybody', 'somepass');
  13.         
  14.         Repeat as requested from User commands:
  15.         if aPop.MailWaiting then begin
  16.             nMsg= aPop->NumberOfMessages();
  17.             for iMsg= 1 to nMsg do begin
  18.                 hMsg= aPop->ReadTop( iMsg, 0);
  19.                 --- collect, display msg directory ----
  20.                 end();
  21.                 
  22.             -- user select msg to read --
  23.             hMsg= aPop->ReadMail( iMsg, True); 
  24.             
  25.             aPop->Release(); -- when done reading for now
  26.             end();
  27.                         
  28.         aPop->Free();  -- when entirely done with mail
  29. */
  30.  
  31. #include "includes.h"
  32. #include "UTCP.h"
  33. #include "UPOP.h"
  34.  
  35. #pragma segment UPOP
  36.  
  37.  
  38. const short        kPOPport = 110; // telnet port 110 == POP3 
  39.  
  40. //const int        kTCPwaitingforopen = 64;
  41. const int        kPOPopen = 128;        // fPOPstates 
  42. const int        kPOPclosed = 256;
  43. const int        kPOPtransaction = 512;
  44.  
  45. const char        chLineFeed    = 10;
  46. const char        chRtn                = 13; 
  47.     
  48.     
  49.  
  50.  
  51. TPOP::TPOP( const CStr255& POPAddress, const CStr63& password)
  52. {
  53.     //ITCP();
  54.     fPOPState= kPOPclosed;
  55.     fPopAddress= POPAddress;
  56.     fPassword= password;  
  57. //-    ResetHost( POPaddress, password); << NEED InstallMessageLine before this 
  58. }
  59.  
  60. TPOP::TPOP()
  61. {
  62.     fPOPState= kPOPclosed;
  63.     fPopAddress= "";
  64.     fPassword= "";  
  65. }
  66.             
  67. TPOP::~TPOP()   
  68. {
  69.     Release();
  70. }
  71.  
  72.  
  73.  
  74.  
  75. void TPOP::ResetHost( const CStr255& POPAddress, const CStr63& password)
  76. {
  77.     fPopAddress= POPAddress;
  78.     fPassword= password; //save for .ReOpen 
  79.     ReOpen();
  80. }
  81.  
  82. void TPOP::ReOpen()
  83. {
  84.     Handle        hMsg; 
  85.     CStr255        aHost, aName;
  86.     short         k;
  87.      
  88.     k= fPopAddress.Pos("@");
  89.     if (k==0) Fail("Bad POP mail address, missing '@'");
  90.     aName= fPopAddress;
  91.     aName[0]=  k-1;
  92.     aHost= fPopAddress;
  93.     aHost.Delete(1,k);
  94.     
  95.     // ?? make sure we are closed 
  96.     if (Status() != kTCPreleased)  this->Release();
  97.     
  98.   this->ShowMessage( aHost);
  99.     fPOPState= kPOPclosed;
  100.     fMsgCount= 0;
  101.     fPOPhostIP= this->NameToAddress( aHost);
  102.   if (fPOPhostIP == 0) Fail("Bad address for POP Host.");
  103.     else {
  104.         ActiveOpen(fPOPhostIP, kPOPport, 0);
  105.         if (Failed()) return;
  106.         if (!WaitedForOpen()) return;
  107.         fPOPState= kPOPopen;
  108.         DisposeIfHandle( RecvChars( CharsAvailable()));    
  109.  
  110.         SendStr("USER " + aName, kAddCRLF);
  111.         hMsg= RecvUpTo( true, chLineFeed, NULL);
  112.         this->ShowMessage( (char *) (*hMsg));
  113.         DisposeIfHandle( RecvChars( CharsAvailable()));
  114.         
  115.         if (**hMsg != '+') 
  116.             Fail( CStr63("Bad username for POP: ") + (char *)(*hMsg) );
  117.         else {
  118.             DisposeIfHandle( hMsg);
  119.             SendStr( "PASS " + fPassword, kAddCRLF);
  120.             hMsg= RecvUpTo( true, chLineFeed, NULL);
  121.             aName= CStr255( (char *)(*hMsg));
  122.             this->ShowMessage( aName);
  123.             DisposeIfHandle( hMsg);
  124.             DisposeIfHandle( RecvChars( CharsAvailable()));
  125.             if (aName[1] != '+') 
  126.                 Fail( "Bad password for POP: "+ aName);
  127.             else {
  128.                 fPOPState= kPOPtransaction;
  129.                 GetMessageCount();
  130.                 }
  131.             }
  132.         DisposeIfHandle( hMsg);
  133.         }
  134. //- this->ShowMessage( State); 
  135. }
  136.  
  137.  
  138. void TPOP::Close() // override 
  139. {
  140.     FailInfo fi;
  141.     if (fi.Try()) {
  142.         if (fPOPState != kPOPclosed) {
  143.             SendStr("QUIT", kAddCRLF);
  144.             fTimeout= 240;
  145.             EatResponseLine();
  146.             fTimeout= gTCPTimeout;
  147.             fPOPState= kPOPclosed;
  148.             }
  149.         TTCP::Close();
  150.         fi.Success();
  151.         }
  152.     else { // fail
  153.         TTCP::Close();
  154.         fi.ReSignal();
  155.         }
  156. }
  157.  
  158. void TPOP::Release() // override 
  159. {
  160.     FailInfo fi;
  161.     if (fi.Try()) {
  162.         if (fPOPState != kPOPclosed) {
  163.             SendStr("QUIT", kAddCRLF);
  164.             fTimeout= 240;
  165.             EatResponseLine();
  166.             fTimeout= gTCPTimeout;
  167.             fPOPState= kPOPclosed;
  168.             }
  169.         TTCP::Release();
  170.         fi.Success();
  171.         }
  172.     else { // fail
  173.         TTCP::Release();
  174.         fi.ReSignal();
  175.         }
  176. }
  177.  
  178.  
  179.  
  180.             
  181. char* TPOP::StatusString(short state)   // override  
  182. {
  183.     CStr255 aState;
  184.     aState= TTCP::StatusString(state);
  185.     switch (fPOPState) {
  186.         case kPOPclosed    : aState=  aState + "; POP closed"; break;
  187.         case kPOPopen        : aState= aState +"; POP connected"; break;
  188.         case kPOPtransaction    : aState= aState +"; POP mailbox open"; break;
  189.         }
  190.     return (char*) aState;
  191. }
  192.  
  193.  
  194. void TPOP::GetMessageCount()
  195. { 
  196.     fMsgCount= 0;
  197.     if (fPOPState == kPOPtransaction) {
  198.         SendStr("STAT", kAddCRLF);
  199.         Handle hMsg= RecvUpTo( true, chLineFeed, NULL); 
  200.         //CStr255 aStr= (char*) (*hMsg);
  201.         this->ShowMessage((char*) (*hMsg));  
  202.         DisposeIfHandle( RecvChars( CharsAvailable()));
  203.         if (**hMsg == '+') {
  204.             char *cp = *hMsg + 3; // skip 3 chars
  205.             //fMsgCount= atol( cp);
  206.             char *cend= strchr(*hMsg, 0);
  207.             while (cp < cend && *cp == ' ') cp++;
  208.             while (cp < cend && *cp != ' ') cp++;
  209.             *cp= 0;
  210.             long aNum= 0;
  211.             stringtonum( cp, &aNum); //<< finicky...
  212.             fMsgCount= (short) aNum;
  213. #if 0
  214.             short len= aStr.Length();
  215.             short i;
  216.             for (i= 1; i<=3; i++) aStr[i]= ' ';
  217.             i= 4; 
  218.             while (i<len  && aStr[i]==' ') i++;
  219.                 //-- aNum= ORD(aStr[i]) - ORD('0'); 
  220.             while (i<len && aStr[i]!=' ') i++;
  221.             if (aStr[i]==' ') i--;
  222.             aStr[0]= i;
  223.             long aNum= 0;
  224.             StringToNum( aStr, aNum); //<< finicky...
  225.             fMsgCount= aNum;
  226. #endif
  227.             }
  228.         DisposHandle( hMsg);
  229.         }
  230. }
  231.  
  232.  
  233. short TPOP::NumberOfMessages()
  234. {
  235.     if (fPOPState == kPOPtransaction) return fMsgCount;
  236.     else return 0;
  237. }
  238.  
  239.  
  240. Handle TPOP::ReadMail(short msgNum, Boolean andDelete)
  241. {
  242.     CStr255  sNum; 
  243.     Handle        hMsg;
  244.  
  245.     if (fPOPState == kPOPtransaction) {
  246.         NumToString( msgNum, sNum);
  247.         SendStr( "RETR " + sNum, kAddCRLF);
  248.         hMsg= RecvMsg( '+', FreeMem() / 2);
  249.         this->ShowMessage( (char*) (*hMsg));
  250.         if ( hMsg == NULL || **hMsg == '•') 
  251.             return NULL;  
  252.         else {
  253.             if (andDelete) DeleteMail( msgNum);
  254.             return hMsg;
  255.             }
  256.         }    
  257.     else
  258.         return NULL;
  259. }
  260.  
  261.  
  262.  
  263. void DropTail( short keeplines, char endLine, short maxEndline, Handle h)
  264. {  
  265.     short        n = 0, linewidth; 
  266.     long        i, hlen;
  267.     char        *buf;
  268.     Boolean        pastHeader = false;
  269.  
  270.     hlen= GetHandleSize(h);
  271.     maxEndline= min( 255, maxEndline);
  272.     for (i= 1, linewidth= 0, buf= *h; 
  273.             i <= hlen; 
  274.             i++, linewidth++, buf++) {
  275.         if (*buf == endLine || linewidth > maxEndline) {
  276.             if (linewidth < 4) pastHeader= true;
  277.             if (pastHeader) n++; 
  278.             linewidth= 0;
  279.             if (n >= keeplines) {
  280.                 SetHandleSize(h, i);
  281.                 return;
  282.                 }
  283.             }
  284.         } 
  285. } 
  286.  
  287. Handle TPOP::ReadTop(short msgNum, short nLines)
  288. {
  289.     CStr255    sNum, sNum2;
  290.     Handle        hMsg;
  291.  
  292.      if (fPOPState == kPOPtransaction) {
  293.         NumToString( msgNum, sNum);
  294.         NumToString( nLines, sNum2);
  295.         SendStr( "TOP " + sNum + " " + sNum2, kAddCRLF);
  296.         hMsg= RecvMsg('+', FreeMem()/2);
  297.         this->ShowMessage( (char*) (*hMsg));
  298.         if (hMsg==NULL || **hMsg == '•') {
  299.             //'TOP' is Optional POP3 msg, try .ReadMail and cut to nLines...
  300.             hMsg= ReadMail( msgNum, false);
  301.             if (hMsg!=NULL) DropTail( nLines, chRtn, 255, hMsg);
  302.             return hMsg; 
  303.             }        
  304.         else 
  305.             return hMsg;
  306.         }    
  307.     else
  308.         return NULL;
  309. }
  310.  
  311.  
  312.  
  313. void TPOP::DeleteMail(short msgNum)
  314. {
  315.     CStr255    sNum;
  316.     Handle        hMsg;
  317.     if (fPOPState == kPOPtransaction) {
  318.         NumToString(msgNum, sNum);
  319.         SendStr( "DELE "+sNum, kAddCRLF);
  320.         hMsg= RecvUpTo( true, chLineFeed, NULL);
  321.         this->ShowMessage( (char*) (*hMsg));
  322.         if (hMsg!=NULL && **hMsg == '+')  ;
  323.         DisposeIfHandle( hMsg);
  324.         DisposeIfHandle( RecvChars( CharsAvailable()));
  325.         }
  326. }
  327.  
  328.  
  329. void TPOP::UnDeleteMail()
  330. {
  331.     Handle    hMsg;
  332.     if (fPOPState == kPOPtransaction) {
  333.         SendStr("RSET",kAddCRLF);
  334.             //count isn't changed by delete/undel >> GetMessageCount; 
  335.         hMsg= RecvUpTo( true, chLineFeed, NULL);
  336.         this->ShowMessage((char*) (*hMsg));
  337.         if (hMsg!=NULL  && **hMsg == '+') ;
  338.         DisposeIfHandle( hMsg);
  339.         DisposeIfHandle( RecvChars( CharsAvailable()));
  340.         }    
  341. }
  342.  
  343.  
  344.  
  345. Boolean TPOP::MailWaiting()
  346. /*general purpose checker:  
  347.     if connection == closed, reopen...
  348.     if mail waiting, return yes && leave open
  349.     if no mail, close connection
  350. ---*/
  351. {
  352.     Boolean        gotsome;
  353.     if (fPOPState != kPOPtransaction || Status() != kTCPestablished)
  354.             ReOpen();
  355.     gotsome= NumberOfMessages() > 0; 
  356.     if (!gotsome) Release();
  357.   this->ShowMessage( StatusString(Status()) ); 
  358.     return gotsome;
  359. }